// import { socket } from "@kit.NetworkKit";
//
// //mock IncomingMessage
// export class IncomingMessage{
//   public headers: Record<string, string | string[]> = {};
//   public method?: string;
//   public url?: string;
//   public statusCode?: number;
//   public socket: socket.TCPSocket;
//   private _rawData: buffer.Buffer[] = [];
//
//   constructor(socket: socket.TCPSocket) {
//     this.socket = socket;
//     this._setupSocketHandlers();
//   }
//
//   private _setupSocketHandlers() {
//   }
//
//   get body(): buffer.Buffer {
//     return buffer.Buffer.concat(this._rawData);
//   }
//
//   destroy(error?: Error): void {
//     this.socket.close()
//   }
// }
//
//
//
// export class ClientHttp2Stream extends Duplex {
//   public id: number;
//   public session: any; // 实际应为Http2Session类型
//   public headersSent: boolean = false;
//   public closed: boolean = false;
//   private _pendingData: buffer.Buffer[] = [];
//
//   constructor(id: number, session: any) {
//     super({ objectMode: true });
//     this.id = id;
//     this.session = session;
//   }
//
//   // 发送HEADERS帧
//   sendHeaders(headers: Record<string, string>) {
//     if (this.headersSent) throw new Error('Headers already sent');
//     this.headersSent = true;
//     this.session._sendHeaders(this.id, headers);
//   }
//
//   // 发送DATA帧
//   _write(chunk: any, encoding: string, callback: Function) {
//     this._pendingData.push(buffer.Buffer.from(chunk));
//     this.session._sendData(this.id, chunk);
//     callback();
//   }
//
//   // 接收远端数据
//   _read(size: number) {
//     while (this._pendingData.length > 0) {
//       const chunk = this._pendingData.shift();
//       if (!this.push(chunk)) break;
//     }
//   }
//
//   push(data){
//     return super.push(data)
//   }
//   // 关闭流
//   close(code?: number) {
//     this.closed = true;
//     this.session._sendRstStream(this.id, code || 0);
//   }
// }